package drds.binlog.parse.inbound;

import drds.binlog.protocol.entry_protocol_proto.Entry;

import java.util.List;

/**
 * 事务刷新机制
 */
public interface TransactionFlushCallback
{

    public void flush(List<Entry> entryList) throws InterruptedException;
}
